c965c5946911063352804e591955e8d1927aed6e,src/main/java/com/continuuity/data/operation/ttqueue/QueuePartitioner.java,HashPartitioner,shouldEmit,#QueueConsumer#number#number#,119
Before Change
@Override
public boolean shouldEmit(QueueConsumer consumer, long entryId, int hash) {
return (hash % consumer.getGroupSize() == consumer.getInstanceId());
}
@Override
After Change
@Override
public boolean shouldEmit(QueueConsumer consumer, long entryId, int hash) {
return (hash % consumer.getGroupSize() == consumer.getInstanceId() % consumer.getGroupSize());
}
@Override